import sys, os
# 将项目根目录加入 sys.path，确保可以导入 src 包
ROOT_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
if ROOT_DIR not in sys.path:
    sys.path.insert(0, ROOT_DIR)

from src.data_processing.pipeline import DataPipeline

def main():
    print("开始优化版本数据预处理...")
    
    # 使用优化配置
    pipeline = DataPipeline("config/optimized_config.yaml")
    
    # 运行优化流水线
    results = pipeline.run_pipeline(save_results=True)
    
    print("✅ 数据预处理完成！")

if __name__ == "__main__":
    main()